60139e59c6f33f91281d3316d65ef8e788e6d85c,streams-contrib/streams-persist-mongo/src/main/java/org/apache/streams/mongo/MongoPersistReader.java,MongoPersistReader,connectToMongo,#,156
Before Change
}
if (!Strings.isNullOrEmpty(config.getUser()) && !Strings.isNullOrEmpty(config.getPassword()))
client.authenticate(config.getUser(), config.getPassword().toCharArray());
if (!client.collectionExists(config.getCollection())) {
client.createCollection(config.getCollection(), null);
After Change
if (!Strings.isNullOrEmpty(config.getUser()) && !Strings.isNullOrEmpty(config.getPassword())) {
MongoCredential credential =
MongoCredential.createCredential(config.getUser(), config.getDb(), config.getPassword().toCharArray());
client = new MongoClient(serverAddress, Lists.<MongoCredential>newArrayList(credential));
} else {
client = new MongoClient(serverAddress);